package com.sugon.ohdfs.integration.flink.util;

import java.time.LocalDateTime;
import java.time.OffsetDateTime;
import java.time.ZoneOffset;

public class DatetimeUtil {

    static ZoneOffset defaultOffset = null;

    public static long getEpochMilli(LocalDateTime dateTime){
        return dateTime==null ? 0 : dateTime.toEpochSecond(ZoneOffset.systemDefault().getRules().getOffset(dateTime));
    }

    public static LocalDateTime getLocalDatetime(long timestamp){
        return LocalDateTime.ofEpochSecond(timestamp, 0, getDefaultOffset());
    }

    public static ZoneOffset getDefaultOffset(){
        if(defaultOffset==null){
            defaultOffset = OffsetDateTime.now().getOffset();
        }
        return defaultOffset;
    }
}
